package com.collect.common.eventbus.exception;

import com.google.common.eventbus.SubscriberExceptionContext;
import com.google.common.eventbus.SubscriberExceptionHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @Author hky
 * @Description
 * @Date 2021/1/18
 */
public class DefaultSubscriberExceptionHandler implements SubscriberExceptionHandler {
    private static final Logger log = LoggerFactory.getLogger(DefaultSubscriberExceptionHandler.class);

    @Override
    public void handleException(Throwable throwable, SubscriberExceptionContext subscriberExceptionContext) {
        log.error(" execute fail by "+throwable.getMessage());
    }
}
